class OBPluginManager:
    @rpc_service
    def list_backups(self, tenant_id):
        """查询备份列表"""
        backups = OBBackupDAO.get_backups(tenant_id)
        return [{
            "id": b.id,
            "type": b.backup_type,
            "size": b.total_size,
            "status": b.status,
            "create_time": b.create_time
        } for b in backups]
    
    @rpc_service
    def create_restore_job(self, backup_id, restore_config):
        """创建恢复任务"""
        validator.check_restore_config(restore_config)
        return RestoreJob.create(backup_id, restore_config)